//package main.scala
//
//
//
//import org.apache.log4j.{Level, Logger}
//import org.apache.spark.graphx.GraphLoader
//import org.apache.spark.sql.SparkSession
//
///**
// * Created by Administrator on 2020/8/18.
// */
//object demo2 {
//  /**
//   * 设置日志级别
//   */
//  Logger.getLogger("org").setLevel(Level.WARN)
//  def main(args: Array[String]) {
//    val spark = SparkSession.builder().appName(s"${this.getClass.getSimpleName}").master("local[2]").getOrCreate()
//    val sc = spark.sparkContext
//
//    // 构建图
//    val graph = GraphLoader.edgeListFile(sc, "D:\\software\\spark-2.4.4\\data\\graphx\\followers.txt")
//
//    // 执行PageRank
//    val ranks = graph.pageRank(0.0001).vertices
//
//    // 加载顶点属性数据
//    val users = sc.textFile("D:\\software\\spark-2.4.4\\data\\graphx\\users.txt").map(row => {
//      val fields = row.split(",")
//      (fields(0).toLong, fields(1))
//    })
//
//    /**
//     * 关联数据
//     */
//    val ranksByUsername = users.join(ranks).map(row => (row._2._1, row._2._2))
//
//    // 打印结果
//    ranksByUsername.foreach(println)
//
//    // 关闭入口
//    spark.stop()
//  }
//}
